package org.lennon.compent.aliyun.rocketmq.starter.sampleexemple.processor;

import com.aliyun.openservices.ons.api.Message;
import org.lennon.compent.aliyun.rocketmq.client.hook.producer.RocketMQProducerHook;
import org.springframework.stereotype.Component;

@Component
public class MyRocketMQProducerHook implements RocketMQProducerHook {

    @Override
    public void before(Message message) {

    }

    @Override
    public void success(Message message) {

    }

    @Override
    public void failue(Message message) {

    }

    @Override
    public void exception(Message message, Throwable throwable) {

    }
}
